package io.netty.shenh.example.inboundoutbound;

import io.netty.channel.ChannelInitializer;
import io.netty.channel.socket.SocketChannel;

public class MyServerInitializer extends ChannelInitializer<SocketChannel> {
    @Override
    protected void initChannel(SocketChannel ch) throws Exception {
//        ch.pipeline().addLast(new MyByte2LongDecoder());
        ch.pipeline().addLast(new MyReplayingDecoder());
        ch.pipeline().addLast(new MyLong2ByteEncoder());
        ch.pipeline().addLast(new MyServerHandler());
        ch.pipeline().addLast(new TestHandler());
    }
}
